package com.tanjie.blackbean.mqtt.properties;

import lombok.Data;
import lombok.EqualsAndHashCode;

/**
 * @author: tanjie
 * @date: 2022-03-03
 **/
@EqualsAndHashCode(callSuper = true)
@Data
public class ConsumerConfig extends ChannelConfig {

    /**
     * 消费者订阅主题，和qos一一对应
     */
    private String[] topics;

    /**
     * qos设置，和topic一一对应
     */
    private int[] qos;

    ExecutorThreadPoolConfig threadPool = new ExecutorThreadPoolConfig();

}
